<Query Kind="Program">
  <Reference>&lt;ProgramFilesX86&gt;\Microsoft Reactive Extensions SDK\v1.0.10621\Binaries\.NETFramework\v4.0\System.Reactive.dll</Reference>
  <Namespace>System.Reactive.Linq</Namespace>
  <Namespace>System.Reactive.Concurrency</Namespace>
  <Namespace>System.Reactive</Namespace>
</Query>

void Main()
{
	var observable = (new int[] {1,2,3}).ToObservable();
	var myObserver = new MyObserver();
	observable.Subscribe(myObserver);
}

class MyObserver : IObserver<int>
{
	public void OnCompleted()
	{
		Console.WriteLine ("Completed");
	}
	
	public void OnError(Exception error)
	{
		Console.WriteLine ("{Error {0}}", error.Message);
	}
	
	public void OnNext(int value)
	{
		Console.WriteLine ("Next {0}", value);
	}
}

